#include "app_mqtt.h"
#include "log/log.h"
#include <unistd.h>

// int recv_callback(char *data, int len)
// {
//     log_debug("recv_callback, data:%s, len:%d", data, len);
//     return 0; // 成功处理一定返回0 =》 否则会导致程序错误结束
// }

// int main(int argc, char const *argv[])
// {
//     app_mqtt_init();

//     app_mqtt_registerRecvCallback(recv_callback);

//     app_mqtt_sendMsg("abcd", 4);

//     sleep(50); // 休眠50秒
//     log_debug("程序即将退出");

//     app_mqtt_close();

//     return 0;
// }

int handle_calback(char *json)
{
    log_debug("处理接收到的数据%s", json);

    return 0;
}
int main(int argc, char const *argv[])
{
    // 初始化
    app_mqtt_init();
    // 注册接收的回调函数
    app_mqtt_registerRecvCallback(handle_calback);
    // 发消息
    app_mqtt_send("{\"name\":\"hmy\"}");

    // 休眠50秒。让当前运行的环境不立即结束
    sleep(20);
    log_debug("程序即将退出");

    // 关闭mqtt连接
    app_mqtt_close();

    return 0;
}
